//import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
//import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
//
///**
// * Todo
// *
// * @author xufeng
// * @version 1.0
// * @date 2022/3/12
// */
//public class SyncAutoConfigure {
//    public static void main(String[] args) throws Exception {
//        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
//        env.setParallelism(1);
//        StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);
//        //2.创建 Flink-MySQL-CDC 的 Source
//        tableEnv.executeSql("CREATE TABLE t_user (" +
//                " USER_ID BIGINT," +
//                " USERNAME STRING," +
//                " PASSWORD STRING" +
//                ") WITH (" +
//                " 'connector' = 'mysql-cdc'," +
//                " 'hostname' = '127.0.0.1'," +
//                " 'port' = '3306'," +
//                " 'username' = 'root'," +
//                " 'password' = 'root'," +
//                " 'database-name' = 'auth-center'," +
//                " 'table-name' = 't_user'" +
//                ")");
//        tableEnv.executeSql("select * from t_user").print();
//        env.execute();
//    }
//}
